package com.lrd.rmqcluster.rmq5;

import org.apache.rocketmq.common.message.MessageExt;

/**
 * 定义一个mq消息消费的接口
 */
public interface MessageProcessor {

    boolean handleMessage(MessageExt msg);
}
